Crate async_nats

A Rust async bleeding edge client for the NATS.io ecosystem.

git clone https://github.com/nats-io/nats.rs

NATS.io is a simple, secure and high performance open source messaging system for cloud native applications, IoT messaging, and microservices architectures.

For sync API refer https://crates.io/crates/nats

For more information see https://nats.io/.

Examples

Below you can find some basic examples how to use this library.

For details, refer docs for specific method/struct.

Complete example

use bytes::Bytes;
use futures::StreamExt;

#[tokio::main]
async fn main() -> Result<(), async_nats::Error> {
    let client = async_nats::connect("demo.nats.io").await?;
    let mut subscriber = client.subscribe("messages".into()).await?.take(10);

    for _ in 0..10 {
        client.publish("messages".into(), "data".into()).await?;
    }

    while let Some(message) = subscriber.next().await {
      println!("Received message {:?}", message);
    }

    Ok(())
}

Publish

let client = async_nats::connect("demo.nats.io").await?;

let subject = String::from("foo");
let data = Bytes::from("bar");
for _ in 0..10 {
    client.publish("subject".into(), "data".into()).await?;
}

Subscribe

let client = async_nats::connect("demo.nats.io").await?;

let mut subscriber = client.subscribe("foo".into()).await.unwrap();

while let Some(message) = subscriber.next().await {
    println!("Received message {:?}", message);
}

Re-exports

• pub use tokio_rustls::rustls;
• pub use header::HeaderMap;
• pub use header::HeaderName;
• pub use header::HeaderValue;
• pub use message::Message;
• pub use status::StatusCode;

Modules

• connection
• header
  NATS Message headers, leveraging http::header crate.
• jetstream
  JetStream is a NATS built-in persistence layer providing Streams with at least once and exactly once semantics.
• message
  A Core NATS message.
• status
  NATS status codes.

Structs

• AuthError
  Error report from signing callback.
• Client
  Client is a Cloneable handle to NATS connection. Client should not be created directly. Instead, one of two methods can be used: crate::connect and crate::ConnectOptions::connect
• ConnectError
  Returned when initial connection fails. To be enumerate over the variants, call ConnectError::kind.
• ConnectInfo
  Info to construct a CONNECT message.
• ConnectOptions
  Connect options. Used to connect with NATS when custom config is needed.
• PublishError
  An error returned from the Client::publish, Client::publish_with_headers, Client::publish_with_reply or Client::publish_with_reply_and_headers functions.
• Request
  Used for building customized requests.
• RequestError
  Error returned when a core NATS request fails. To be enumerate over the variants, call RequestError::kind.
• ServerAddr
  Address of a NATS server.
• ServerInfo
  Information sent by the server back to this client during initial connection, and possibly again later.
• Subscriber
  Retrieves messages from given subscription created by Client::subscribe.
• UnsubscribeError

Enums

• CallbackError
• ClientError
• ClientOp
  ClientOp represents all actions of Client.
• Command
• ConnectErrorKind
• Event
• Protocol
  Protocol version used by the client.
• RequestErrorKind
• ServerError

Traits

• ToServerAddrs
  Capability to convert into a list of NATS server addresses.

Functions

• connect
  Connects to NATS with default config.
• connect_with_options
  Connects to NATS with specified options.

Type Definitions

• Error